package initialize

import (
	"cron_table_admin/global"
	"cron_table_admin/mq"
)

// InitNsqMq nsq处理
func InitNsqMq() {
	nsqAddress := global.SERVER_CONFIG.MqConfig.NsqAddress

	//处理topic:test的消息逻辑
	go mq.NewNsqConsumer("test", "xx", nsqAddress)

	/*TODO 处理其他topic消息逻辑*/
}
